package com.wo56.pushmsgcenter.business.consumer.impl;

import java.util.Map;

import com.framework.core.pushmsgcenter.po.PushMsgBean;
import com.framework.core.pushmsgcenter.util.PushMsgConst;
import com.wo56.pushmsgcenter.business.consumer.interfaces.IConsumeMsg;

public class ConsumeMsgImpl implements IConsumeMsg {

	@Override
	public Map consumeMsg(PushMsgBean msg) {
		//针对消息类型 处理一些业务逻辑。
		//1.保存？
		//2.分类型处理
		//3.保存结果
		switch (msg.getMsgType()) {
		case PushMsgConst.MsgType.wechat:
			//走异步的方式  从志鸿复制task过来？还是直接通过消费消息来处理？
			break;
		case PushMsgConst.MsgType.message:
			//走异步的方式 从志鸿复制通用的task过来？还是直接通过消费消息来处理？
			break;
		case PushMsgConst.MsgType.webpush:
			//直接push出去
			break;
		default:
			break;
		}
		return null;
	}

}
